"""
数据采集模块

负责金融数据的采集、清洗和实时处理，集成Kafka消息队列和Flink流处理，
确保数据的实时性和准确性。
"""

from .storage.kafka_client import KafkaClient
from .storage.hdfs_client import HDFSClient

__all__ = [
    'KafkaClient',
    'HDFSClient'
]